package com.bsj.power.pls.queue.service;

import org.springframework.stereotype.Service;

/**
 * @ClassName QueueService
 * @Description 队列服务
 * @Author yinhao
 * @Date 2024/8/19 22:12
 **/
@Service
public interface QueueService {
    /**
     * 启动
     **/
    void init();
    /**
     * 停止
     **/
    void stop();
    /**
     * 执行
     **/
    void doRun(Object bytes) throws Exception;

    void doPush(byte[] bytes) throws Exception;
}
